package com.ydl.learning.flink.demo.pipeline.java.impl;

import com.ydl.learning.flink.demo.pipeline.java.Process;
import org.apache.flink.streaming.api.datastream.DataStream;

/**
 *
 */
public class ConditinoFilterProcessImpl<T> extends BaseProcedureImpl implements Process<T> {

  /**
   * Default constructor
   */
  public ConditinoFilterProcessImpl() {
  }

  /**
   *
   */
  @Override
  public void setTable(DataStream<T> result) {
    // TODO implement here
  }

  /**
   *
   */
  @Override
  public DataStream<T> run() {
    // TODO implement here
    return null;
  }

}